
import pymysql

from mysql_util import MysqlUtil

connectiont = pymysql.connect(
    host = 'localhost', # 主机名
    user = 'root',      # 数据库用户名
    password = '',  # 数据库密码
    db = 'test',      # 数据库名
    charset = 'utf8',   # 字符集编码
    cursorclass = pymysql.cursors.DictCursor # 游标类型
)

# 数据列表
data = [('1','小炸弹音箱 迷你音箱 银色表','45','38','/static/img/p2.png'),
        ('2','小炸弹音箱 迷你音箱 橙色表','45','38','/static/img/p3.png'),
        ('3','小炸弹音箱 迷你音箱 紫色表','45','38','/static/img/p4.png'),
        ('4','小炸弹音箱 迷你音箱 可爱表','45','38','/static/img/p5.png'),
        ]


cursor = connectiont.cursor() # 获取游标对象
try:
    # 执行sql语句，插入多条数据
    cursor.executemany("INSERT INTO product_temp(id, pname, old_price, new_price, images) VALUES (%s, %s, %s, %s, %s)", data)
    # 提交数据
    connectiont.commit()
except:
    # 发生错误时回滚
    print("发生错误时回滚")
    connectiont.rollback()
print("ok")
connectiont.commit()
cursor.close()      # 关闭游标
connectiont.close() # 关闭连接
